package com.marion.mrpc.transport;

import com.marion.mrpc.Peer;

import java.io.InputStream;

/**
 * 传输客户端
 *     1. 创建链接
 *     2. 发送数据，并且等待响应
 *     3. 关闭连接
 * @author marion
 * @date 2021/9/4
 */
public interface TransportClient {

    void connect(Peer peer);

    InputStream write(InputStream stream);

    void close();
}
